package drds.binlog.parse;

import drds.binlog.common.Authors;
import drds.common.Author;

/**
 * receive parsed bytes , 用于处理要解析的数据块
 */
@Author(name = Authors.LI_YANG)
public interface SinkFunction<Event>
{

    public boolean sink(Event event);
}
